package cron

import (
	"fiber/utils"
	"log"
)

// var lock sync.Mutex

// var p atomic.Value

// 测一下redis
func TestRedis() {

	log.Println(utils.Get("http://127.0.0.1:8888"))

	// redis := global.Redis
	// lock.Lock()
	// // 原子操作？
	// incr := redis.Incr("num")
	// log.Println(incr.Val())
	// lock.Unlock()

	// 并发读取有问题

	// // 开启一个TxPipeline事务
	// pipe := redis.TxPipeline()
	// // log.Println(pipe.Get("num"))

	// // 执行事务操作，可以通过pipe读写redis
	// incr := pipe.IncrBy("num", 0)
	// _, err := pipe.Exec()
	// if incr.Val() > 320 {
	// 	return
	// }
	// log.Println(incr.Val(), err)

	// // 上面代码等同于执行下面redis命令
	// //
	// //     MULTI
	// //     INCR pipeline_counter
	// //     EXPIRE pipeline_counts 3600
	// //     EXEC

	// incr1 := pipe.Incr("num")
	// // 通过Exec函数提交redis事务
	// _, err = pipe.Exec()

	// // 提交事务后，我们可以查询事务操作的结果
	// // 前面执行Incr函数，在没有执行exec函数之前，实际上还没开始运行。
	// log.Println(incr1.Val(), err)

}
